/*
 * SocketMsgSender.h
 *
 *  Created on: 20/06/2011
 *      Author: wadi
 */

#ifndef SOCKETMSGSENDER_H_
#define SOCKETMSGSENDER_H_
#include "socket.h"
#include "thread.h"
#include "blockingqueue.h"
#include <log4cxx/logger.h>
#include <vector>
class SocketMsgSender: public Thread{
public:
  SocketMsgSender();
  SocketMsgSender(BlockingQueue* msgQueue,Socket* socketTcp);
  virtual void run();
  void close();
  virtual
  ~SocketMsgSender();
private:
  Socket* socket;
  BlockingQueue* queue;
  bool closed;
  log4cxx::LoggerPtr logger_;
};

#endif /* SOCKETMSGSENDER_H_ */
